package com.omuao.cloud.stabilization.message.producer;

import com.omuao.cloud.stabilization.common.message.annotation.MessageQueue;
import com.omuao.cloud.stabilization.common.message.annotation.MessageQueueInsert;
import org.springframework.stereotype.Component;

/**
 * 消息生产者
 *
 * @author yumi
 */
@MessageQueue("demo")
@Component("demo")
public class MessageStreamProducerImpl implements MessageStreamProducer {
    /**
     * 发送demo消息
     *
     * @param message 消息
     * @return
     */
    @Override
    @MessageQueueInsert("test")
    public boolean sendMessageDemo(String message) {
        return false;
    }
}
